package com.kafka;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class ProducerFastStart {
    private static final String TOPIC = "";

    public static void main(String[] args) {


        Properties properties = new Properties();

        properties.put("bootstrap.servers","192.168.137.136:9092");
        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
        properties.put(ProducerConfig.RETRIES_CONFIG,10);
        properties.put(ProducerConfig.ACKS_CONFIG,"all");
        //生产者对象
        KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);


        ProducerRecord<String,String> record = new ProducerRecord<String, String>(TOPIC,"00001","hello word");

        try {
            producer.send(record);
        }catch (Exception e){
            e.printStackTrace();
        }

        //关系消息通道
        producer.close();
    }
}
